package com.fr.base.core.antlr;

import java.io.IOException;
import java.io.InputStream;

public class ByteBuffer extends InputBuffer
{
  public transient InputStream input;

  public ByteBuffer(InputStream paramInputStream)
  {
    this.input = paramInputStream;
  }

  public void fill(int paramInt)
    throws CharStreamException
  {
    try
    {
      syncConsume();
      while (this.queue.nbrEntries < paramInt + this.markerOffset)
        this.queue.append((char)this.input.read());
    }
    catch (IOException localIOException)
    {
      throw new CharStreamIOException(localIOException);
    }
  }
}